package com.weichuang.springBootRabbmitMQ.receiver;

import lzzsrj.union.message.redis.listener.RedisMQListener;
import lzzsrj.union.message.common.bean.UnionMessage;
import org.springframework.stereotype.Component;

@Component
public class RedisMQConsumer {
    @RedisMQListener(topic = "create_policy", interval = 2000, quantity = 2)
    public void redisMQ(UnionMessage redisMQMessage) {
        System.out.println(redisMQMessage.getQueue() + "队列收到消息：" + redisMQMessage);
    }
}